//package com;
//
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import java.io.*;
//import java.net.InetSocketAddress;
//import java.net.Socket;
//
///**
// * java客户端
// */
//public class SocketClient extends Thread {
//    private static final Logger logger = LoggerFactory.getLogger(SocketClient.class);
//    private static boolean flag = false;
//    public static Socket socket = new Socket();
//
//    public static void main(String[] args) throws IOException {
//        try {
//            connect();
//            String bookAlarm = "GET / HTTP/1.1\r\n" +
//                    "Content-Length: 0\r\n" +
//                    "Content-Type: application/json\r\n" +
//                    "Connection: keep-alive\r\n" ;
//
//            // 向服务端发消息
//            sendMessage(bookAlarm);
//            // 持续接受服务端消息
//            receiveMessage();
//        } catch (Exception e) {
//            logger.info("异常关闭，异常信息：{}", e);
//        }
//        socket.close();
//        logger.info("客户端已退出~");
//    }
//
//
//    /**
//     * 接受服务端消息
//     * @throws IOException
//     */
//    private static void receiveMessage() throws IOException {
//        // 得到socket输入流，并转换为BufferedReader
//        InputStream inputStream = socket.getInputStream();
//
//        String tag = "\r\n\r\n";
//        String tag2 = "\r\n";
//        ByteArrayOutputStream output = new ByteArrayOutputStream();
//        int n;
//        while ((n = inputStream.read()) != -1) {
//            if (flag) {
//                output = new ByteArrayOutputStream();
//                flag = false;
//            }
//            output.write(n);
//            String headStr = output.toString();
//            int contentLength = 0;
//            if (headStr.contains(tag)) {
//                String[] split = headStr.split(tag2);
//                for (String contentLine : split) {
//                    if (contentLine.contains("Content-Length:")) {
//                        contentLength = Integer.parseInt(contentLine.split("Content-Length:")[1].trim());
//                        break;
//                    }
//                }
//                int count = 0;
//                while
//                }
//            }
//        }
//    }
//
//    private static void connect() {
//        try {
//            // 超时时间
//            socket.setSoTimeout(30 * 1000);
//            // 连接本地，超时时间3s
//            socket.connect(new InetSocketAddress("192.168.1.103", 8088), 30 * 1000);
//            logger.info("已发起服务器连接，并进入后续流程");
//            logger.info("客户端信息：" + socket.getLocalAddress() + " port:" + socket.getLocalPort());
//            logger.info("服务端信息：" + socket.getInetAddress() + " port:" + socket.getPort());
//        } catch (Exception e) {
//            logger.error("连接服务器异常，异常信息：{}", e);
//        }
//    }
//
//
//    /**
//     * 向服务端发消息
//     * @param message
//     * @throws IOException
//     */
//    public static void sendMessage(String message) {
//        // 得到socket输出流，并转换为打印流
//        OutputStream outputStream;
//        PrintStream socketPrintStream;
//        try {
//            outputStream = socket.getOutputStream();
//            // 用此方法发送可收到回包
//            socketPrintStream = new PrintStream(outputStream);
//            logger.info("向服务端发消息：{}", message);
//            socketPrintStream.println(message);
//        } catch (Exception e) {
//            logger.error("客户端发送消息异常：{}", e);
//        }
//    }
//
//
//
//}
